package com.chaihu.api.listener;

import com.alibaba.fastjson.JSONObject;
import com.chaihu.core.context.DataFlowContext;
import com.chaihu.core.event.service.api.ServiceDataFlowEvent;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.client.RestTemplate;

/**
 * 主要目的将soService 方法拆分为校验部分 和业务处理部分
 */
@Slf4j
public abstract class AbstractServiceApiListener extends AbstractServiceApiDataFlowListener {

    //订单服务统一地址，这个不会变，直接在这里写死
    private String ORDER_SERVICE_URL = "http://order-service/orderApi/service";

    @Autowired
    private RestTemplate restTemplate;

    /**
     * 业务处理
     *
     * @param event
     */
    public final void soService(ServiceDataFlowEvent event) {

        DataFlowContext dataFlowContext = event.getDataFlowContext();
        //获取请求数据
        JSONObject reqJson = dataFlowContext.getReqJson();

        log.debug("API服务 --- 请求参数为：{}", reqJson.toJSONString());
        dataFlowContext.setResponseEntity(null);

        validate(event, reqJson);

        doSoService(event, dataFlowContext, reqJson);

    }

    /**
     * 数据格式校验方法
     *
     * @param event   事件对象
     * @param reqJson 请求报文数据
     */
    protected abstract void validate(ServiceDataFlowEvent event, JSONObject reqJson);


    /**
     * 业务处理类
     *
     * @param event   事件对象
     * @param context 数据上文对象
     * @param reqJson 请求报文
     */
    protected abstract void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson);


    @Override
    public int getOrder() {
        return 0;
    }


}
